草庐IT

SpringCloud Stream整合RocketMQ

全部标签

【Flink-Kafka-To-RocketMQ】使用 Flink 自定义 Sink 消费 Kafka 数据写入 RocketMQ

【Flink-Kafka-To-RocketMQ】使用Flink自定义Sink消费Kafka数据写入RocketMQ1)准备环境2)代码实现2.1.主程序2.2.conf2.2.1.ConfigTools2.3.utils2.3.1.DBConn2.3.2.CommonUtils2.4.function2.4.1.MqSinkFunction2.5.resources2.5.1.appconfig.yml2.5.2.log4j.properties2.5.3.log4j2.xml1)准备环境这里的maven依赖比较冗余,推荐大家都加上,后面陆续优化。projectxmlns="http://m

若依分离版整合单元测试

1、添加依赖,必须添加在admin的pom文件中,要不然起不来(找不到启动类)dependency>groupId>org.springframework.boot/groupId>artifactId>spring-boot-starter-test/artifactId>scope>test/scope>/dependency>2、创建文件夹目录,测试类TestDemo必须写在com.cxjk下,或者com.cxjk下新建其他目录中,要不然会报错(找不到@Autowired注入的),该测试类可作为最外层公共的,在建立controller,service包下对应的测试类packagecom.

基于RocketMQ实现分布式事务

前言在上一篇文章SpringBoot自动装配原理以及实践我们完成了服务通用日志监控组件的开发,确保每个服务都可以基于一个注解实现业务功能的监控。而本文我们尝试基于RocketMQ实现下单的分布式的事务。可能会有读者会有疑问,之前我们不是基于Seata完成了分布式事务,为什么我们还要用到RocketMQ呢?我们的再来回顾一下我们下单功能大抵是做以下三件事情:创建订单,将订单记录存到数据库中。扣款,记录用户扣款后钱包所剩下的额度。扣除商品库存,并发放商品。我们将该场景放到高并发场景下,这个功能势必要考虑性能和可靠性问题,所以我们在业务需求清楚明了的情况下,就希望能有一种方式确保下单功能在高并发场景

深入解析Freemarker模板引擎及其在Spring Boot中的高级整合

目录引言1.Freemarker1.1.什么是Freemarker1.2Freemarker模板组成部分1.3.优点2.SpringBoot整合Freemarker2.1配置2.2数据类型3.案例总结引言Freemarker作为一款强大的模板引擎,与SpringBoot的整合能够极大地提升Web应用的开发效率和灵活性。本篇博客将深入探讨Freemarker的原理和核心概念,并重点介绍在SpringBoot项目中如何配置和应用Freemarker模板引擎。通过全面讲解与丰富示例,旨在帮助读者充分理解并熟练运用这一强大的技术组合。1.Freemarker1.1.什么是FreemarkerFreeM

Bert-vits2-2.3-Final,Bert-vits2最终版一键整合包(复刻生化危机艾达王)

近日,Bert-vits2发布了最新的版本2.3-final,意为最终版,修复了一些已知的bug,添加基于WavLM的Discriminator(来源于StyleTTS2),令人意外的是,因情感控制效果不佳,去除了CLAP情感模型,换成了相对简单的BERT融合语义方式。事实上,经过2.2版本的测试,CLAP情感模型的效果还是不错的,关于2.2版本,请移步:Bert-vits2-v2.2新版本本地训练推理整合包(原神八重神子英文模型miko)更多情报请关注Bert-vits2官网:https://github.com/fishaudio/Bert-VITS2/releases/tag/v2.3本

SpringBoot3中Swagger整合knife4j和springdoc的配置说明

 springboot3开始javax包改成了jakarta,而swagger-oas等包中依然使用的是javax所以报错。另外springfox已经过时了,两年没更新了,并且不支持OpenAPI3标准,而SpringBoot3只支持OpenAPI3规范,所以要迁移到springdocKnife4J是一款基于Swagger快速生成API文档和调试平台的开源工具,它可以轻松地将Swagger规范转换成易于阅读的文档,并支持在线测试API。Knife4J内置了多种主题和插件,提供了丰富的样式和功能配置,可以自定义API文档的展示方式和内容。OpenAPI3的规范,目前针对Java的SpringBo

SpringBoot(3)整合MyBatis 和MybatisPlus

SpringBoot(3)整合MyBatis和MybatisPlus1.整合MyBatis1.1新建模块1.2在pom.xml中添加mysql驱动1.2.1防止编译时不将静态资源编译进去,在pom.xml中添加1.3.application.yml中添加内容1.2.resources中添加generatorConfig.xml1.3在pom中添加插件1.4测试1.5.新建一个controller包,添加JdbcController1.6启动项目2.整合MybatisPlus2.1添加依赖2.2添加MyBatis配置类2.3启动配置类2.4发现一个问题,MyBatisPlus自动生成的实体类没有

springboot通过springdata整合es7.x

首先要明确通过springdata操作es必须要将版本号和es的版本号对应上,否则会报错(倒不用完全一一对应,但版本号最好不要相差太多)。springdata引入的版本号由springboot的版本号决定,对应关系如下:这里我用的版本号分别是:es:elasticsearch:7.10.1springboot:spring-boot-starter-parent:2.7.8springdata:spring-boot-starter-data-elasticsearch:2.7.81、引入依赖,只关注springboot和es的部分就行?xmlversion="1.0"encoding="UT

【后端-Quartz】Springboot整合Quartz支持集群环境-设计业务与框架分离及实现定时任务调度

目录背景简单设计开始集成quartz总结背景我们的各个服务需要改造支持集群,现在的授权、日程使用的是基于内存的springscheduler定时任务,如果部署多个节点,那么到了时间点,多个节点都会开始执行定时任务从而可能引起业务和性能上的问题。服务中的定时任务比较轻量,为了避免引入redis、zookeeper、单独的定时任务程序,所以建议选用quartz这种基于数据库的分布式定时任务调度框架,无需引用多余中间件。简单设计原则上是尽量与quartz的耦合降至最低,针对我们的业务场景并不需要太多的调度操作(即图上的controller),只需要程序启动的时候初始化好指定的定时任务就行了,所以先这

【SpringBoot2】开发实用篇-整合第三方技术(任务、邮件)

🍎个人主页:亮点菌的博客🍊个人信条:点亮编程之路,做自己的亮点🍓参加活动:CSDN话题挑战赛第2期🍅参赛话题:学习笔记🥭开发实用篇系列内容:热部署配置高级测试数据层解决方案整合第三方技术监控文章目录1、任务(1)Quartz(2)Task2、邮件(1)发送简单邮件(2)发送多组件邮件(附件、复杂正文)1、任务​springboot整合第三方技术第二部分我们来说说任务系统,其实这里说的任务系统指的是定时任务。定时任务是企业级开发中必不可少的组成部分,诸如长周期业务数据的计算,例如年度报表,诸如系统脏数据的处理,再比如系统性能监控报告,还有抢购类活动的商品上架,这些都离不开定时任务。本节将介绍两种